package com.atguig.mq.listener;
  
import org.springframework.amqp.core.Message;  
import org.springframework.amqp.core.MessageListener;  
  
public class TopicListenerWell_1 implements MessageListener {  
  
    public void onMessage(Message message) {  
  
        try {  
  
            String msg = new String(message.getBody(), "utf-8");  
  
            System.out.printf("通配符#监听器 1：接收路由名称为：%s,路由键为：%s,队列名为：%s的消息：%s \n",  
            message.getMessageProperties().getReceivedExchange(),  
            message.getMessageProperties().getReceivedRoutingKey(),  
            message.getMessageProperties().getConsumerQueue(),  
            msg);  
  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
    }  
}